var Post = require("../models/post");
var redis = require("redis");
var config = require('../config');

var Post = new Post();
var k = 1;
setInterval(function() {
		//从数据库取出状态为0的贴子
		Post.findPostByOptions({
			state: 0
		}, function(err, datas) {
			for (var i = 0; i < datas.length; i++) {
				var tiezi_id = datas[i]._id;
				var con = datas[i].content;
				var tx = con.replace(/[\s\r\n]/g, "");
				Post.updateStateById(tiezi_id, 1, function(err) {
					console.log(err);
				});
				checkstr(tx, tiezi_id);
			}
			console.log(k);
			k++;
		})
	},
	// 60秒查询一次
	config.timer
);

function checkstr(tx, tiezi_id) {
	//连接Redis数据库，通过遍历敏感词组来判断
	client = redis.createClient(6379, config.redis_ip);
	client.on("error", function(err) {
		console.log("Error: " + err);
	});
	for (var j = 1; j <= 1084; j++) {
		client.get(j.toString(), function(err, reply) {
			var word = reply.replace(/\s+/g, "");
			var regExp = new RegExp("\\" + word, "g");
			if (regExp.test(tx)) {
				//包含敏感词的贴子修改数据库状态为:2,为审查后不合格
				Post.updateStateById(tiezi_id, 2, function(err) {
					console.log(err);
				});
			}
		});
	};
	client.quit();
}